//package com.xiao.websocket;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.web.socket.CloseStatus;
//import org.springframework.web.socket.WebSocketHandler;
//import org.springframework.web.socket.WebSocketMessage;
//import org.springframework.web.socket.WebSocketSession;
//
///**
// * @Describe: websocket拦截器（spring实现）
// * @Author: yangchengxiao
// * @Date: 2021/4/14 16:56
// */
//@Slf4j
//public class MyWebSocketHandler implements WebSocketHandler {
//
//    /**
//     * 连接建立
//     * @param webSocketSession
//     * @throws Exception
//     */
//    @Override
//    public void afterConnectionEstablished(WebSocketSession webSocketSession) throws Exception {
//        log.info("已建立连接………………, sessionId: {}", webSocketSession.getId());
//    }
//
//    /**
//     * 接收到消息
//     * @param webSocketSession
//     * @param webSocketMessage
//     * @throws Exception
//     */
//    @Override
//    public void handleMessage(WebSocketSession webSocketSession, WebSocketMessage<?> webSocketMessage) throws Exception {
//        log.info("接收到消息, message: {}, sessionId: {}", webSocketMessage.getPayload(), webSocketSession.getId());
//        webSocketSession.sendMessage(webSocketMessage);
//    }
//
//    /**
//     * 连接出错
//     * @param webSocketSession
//     * @param throwable
//     * @throws Exception
//     */
//    @Override
//    public void handleTransportError(WebSocketSession webSocketSession, Throwable throwable) throws Exception {
//        log.error("连接发生错误, sessionId: {}", webSocketSession.getId(), throwable);
//    }
//
//    /**
//     * 连接已关闭
//     * @param webSocketSession
//     * @param closeStatus
//     * @throws Exception
//     */
//    @Override
//    public void afterConnectionClosed(WebSocketSession webSocketSession, CloseStatus closeStatus) throws Exception {
//        log.info("已关闭连接………………, sessionId: {}", webSocketSession.getId());
//    }
//
//    @Override
//    public boolean supportsPartialMessages() {
//        return false;
//    }
//}
